package com.mtiiot.fscore.bean;

import java.io.Serializable;

/**
 * 异步消息结构体
 * Created by lcy on 16-7-22.
 */
public class MqInfo implements Serializable {
    /**
     * 主题
     */
    private String topic;
    /**
     * 键值 key
     */
    private String key;
    /**
     * 键值 value
     */
    private Object value;

    /**
     * 消费者使用时用得到
     */
    private int reTryTime=0;

    public MqInfo(){}
    public MqInfo(String topic, String key, Object value) {
        this.topic = topic;
        this.key = key;
        this.value = value;
    }

    public int getReTryTime() {
        return reTryTime;
    }

    public void setReTryTime(int reTryTime) {
        this.reTryTime = reTryTime;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    public Object getValue() {
        return value;
    }

    public void setValue(Object value) {
        this.value = value;
    }
}
